package top.xiaocao.rx.java.filter.function;

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.functions.Consumer;
import io.reactivex.rxjava3.functions.Function;

/**
 * @className:MapDemo 
 * @comment: 注释信息 
 * @date:     2024年2月13日 上午8:01:25 
 * @author   zhengchong.wan
 * @since    V1.0.0	 
 */
public class MapDemo {

	public static void main(String[] args) {
		Observable.just(1, 2, 3, 4, 5)
				//使用Map操作符中的Function函数对被观察者发送的事件统一作出处理
				.map(new Function<Integer, Integer>() {
					@Override
					public Integer apply(Integer integer) throws Exception {
						//对被观察者just发送的结果，都全部乘以10处理
						return integer * 10;
					}
				}).subscribe(new Consumer<Integer>() {//订阅
					@Override
					public void accept(Integer integer) throws Exception {//接受事件结果，是处理后的结果
						System.out.println("map：accept == " + integer);
					}
				});
	}

}
